package io.jnet.common.api;

import com.jfireframework.baseutil.collection.buffer.ByteBuf;
import io.jnet.common.bufstorage.BufStorage;
import io.jnet.common.streamprocessor.StreamProcessor;

public interface ReadProcessor
{
    void process(ByteBuf<?> buf, BufStorage bufStorage, StreamProcessor[] inProcessors, ChannelContext channelContext) throws Throwable;
}
